Skip to content

add pause/resume queue methods - #135

Merged
ggueret merged 6 commits into
pricingassistant:masterfrom
FlorianPerucki:master
Oct 26, 2016
Merged

add pause/resume queue methods#135
ggueret merged 6 commits into
pricingassistant:masterfrom
FlorianPerucki:master

Conversation

@FlorianPerucki

Copy link
Copy Markdown
Contributor

No description provided.

Comment thread mrq/worker.py Outdated
gevent.sleep(0.01)

jobs = []
paused_queues = Queue.redis_paused_queues()

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

à passer dans un greenlet avec interval paramétrable, comme les subqueues

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

  • si intervale à zéro, couper le greenlet (et faire pareil dans subqueues?)

@ggueret
ggueret merged commit 0e7a91a into pricingassistant:master Oct 26, 2016
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants